package com.sugon.ww

import org.apache.spark.rdd.RDD

class SearchFunctions(val query: String) {


  def isMatch(s: String): Boolean = {
    s.contains(query)
  }


  def getMatchesFunctionReference(rdd: RDD[String]): RDD[Boolean] = {
    // 问题:"isMatch"  "this.isMatch"，    要    "this"
    rdd.map(isMatch)
  }

  def getMatchesFieldReference(rdd: RDD[String]): RDD[Array[String]] = {
    // 问题:"query"  "this.query"，    要    "this"
    rdd.map((x: String) => x.split(query))
  }

  def getMatchesNoReference(rdd: RDD[String]): RDD[Array[String]] = {
    //   :    需要的字  出      量中
    val query_ : String = this.query

    rdd.map((x: String) => x.split(query_))
  }


}